一、准备 1、启动zookeeper 2、启动kafka 3、kafka创建主题。主题名称为：couponTopic ./kafka-topics.sh --create --zookeep ...

zookeepe版本: zookeeper-3.4.13, 安装路径/usr/local/zookeeper-3.4.13/ kafka版本：kafka_2.13-2.6.0.tgz ...

一、生产者负载均衡 1、分区器 使用分区器，kafka生产消息时，根据分区器将消息投递到指定的分区中。 Kafka默认的分区器时DefaultPartitioner。它的分区策略是根据key进行 ...